package old.day20190318.statements;

/**
 * @author DingZhenYun
 * @create 2019-03-18 11:18
 */

import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

/**
 * 通过 JDBC 向指定的数据表中插入一条记录.
 *
 * 1. Statement: 用于执行 SQL 语句的对象
 * 1). 通过 Connection 的 createStatement() 方法来获取
 * 2). 通过 executeUpdate(sql) 可以执行 SQL 语句.
 * 3). 传入的 SQL 可以是 INSRET, UPDATE 或 DELETE. 但不能是 SELECT
 *
 * 2. Connection、Statement 都是应用程序和数据库服务器的连接资源. 使用后一定要关闭.
 * 需要在 finally 中关闭 Connection 和 Statement 对象.
 *
 * 3. 关闭的顺序是: 先关闭后获取的. 即先关闭 Statement 后关闭 Connection
 */
public class Test1 {
    public static void main(String[] args) {
        //testStatement();
        testStatement1();
    }
    /* 通用的更新的方法: 包括 INSERT、UPDATE、DELETE
     版本 1. */
    private static void update(String sql) {

        Connection conn=null;
        Statement statement=null;
        try {
            conn=JDBCTools.getConnection();
            statement=conn.createStatement();
            statement.executeUpdate(sql);
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            JDBCTools.release(statement,conn);
        }

    }

    public static Connection getConnection3() throws Exception{
        //1. 准备连接数据库的 4 个字符串.
        //1). 创建 Properties 对象
        Properties properties=new Properties();
        //2). 获取 jdbc.properties 对应的输入流
        InputStream is=Test1.class.getClassLoader().getResourceAsStream("jdbc.properties");

        //3). 加载 2） 对应的输入流
        properties.load(is);
        //4). 具体决定 user, password 等4 个字符串.
        String driver=properties.getProperty("driver");
        String jdbcUrl=properties.getProperty("jdbcUrl");
        String password=properties.getProperty("password");
        String user=properties.getProperty("user");
        //2. 加载数据库驱动程序(对应的 Driver 实现类中有注册驱动的静态代码块.)
        Class.forName(driver);
        //3. 通过 DriverManager 的 getConnection() 方法获取数据库连接.
        return DriverManager.getConnection(jdbcUrl,user,password);
    }
    private static void testStatement() {
        //1. 获取数据库连接
        Connection conn=null;
        Statement statement=null;
        try{
             conn=getConnection3();
             statement=conn.createStatement();
             String sql=null;
            //4. 执行插入.
            //1). 获取操作 SQL 语句的 Statement 对象:
            //调用 Connection 的 createStatement() 方法来获取
             //sql="insert into t_uesrs(username,password) values('888888','888888')";
            // sql="delete from t_users where id=8";
             sql="update t_users set nickname='sb' where id=1";
            //2). 调用 Statement 对象的 executeUpdate(sql) 执行 SQL 语句进行插入
             statement.executeUpdate(sql);
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            if(statement!=null){
                try {
                    //5. 关闭 Statement 对象.
                    statement.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            //2.关闭连接
            if(conn!=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
    private static void testStatement1() {
        String sql="update t_users set nickname='sb2' where id=2";
        update(sql);
    }
}
